package com.fafi.rxjava2.operator;

public abstract class CallerWithUpstream<T, R> extends Caller<R> implements CallerSource<T> {
    protected final Caller<T> source;

    public CallerWithUpstream(Caller<T> source) {
        this.source = source;
    }

    @Override
    public Caller<T> source() {
        return source;
    }

}